ConcurrentSubjectAsync class¶
Defined in
Namespace: ReactiveUI.Extensions.Async.Subjects
Assembly: ReactiveUI.Extensions.dll
Full name: ReactiveUI.Extensions.Async.Subjects.ConcurrentSubjectAsync<T>
Modifiers: public sealed
Summary¶
Provides an asynchronous subject that forwards notifications to observers concurrently.
Applies to
net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481
Class hierarchy
classDiagram
class ConcurrentSubjectAsync~T~
class BaseSubjectAsync~T~
BaseSubjectAsync~T~ <|-- ConcurrentSubjectAsync~T~
Inherits from: BaseSubjectAsync
Remarks¶
Observers are notified in parallel for each event. This class is suitable for scenarios where high throughput and concurrent notification of multiple observers are required. Thread safety is ensured for observer notification operations. Cancellation tokens can be used to cancel ongoing notification tasks.
Constructors¶
| Name | Summary |
|---|---|
| .ctor |
Methods¶
| Name | Summary |
|---|---|
| OnNextAsyncCore | Forwards the specified value to all observers asynchronously. |
| OnErrorResumeAsyncCore | Handles an error by resuming asynchronous observation for each observer in the collection. |
| OnCompletedAsyncCore | Notifies all observers of the completion event asynchronously. |